<!DOCTYPE html>
<html>
  
<head><meta name="generator" content="Hexo 3.8.0">
  <meta charset="utf-8">
  <meta name="author" content="Amos Zhu">
  
  
  <title>面试那点事儿（二） | Amos的技术博客</title>

  <meta name="viewport" content="width=device-width, initial-scale=1, maximum-scale=1">

  
    <meta name="keywords" content="rabbitMQ,rabbitMQ,">
  

  
  <meta name="description" content="本博文接上篇《RabbitMQ面试那点事儿》，再梳理下RabbitMQ关于面试的一些知识点，本博文包含了RabbitMQ集群和高可用方面的知识">

  

  
    <script src="//cdn.jsdelivr.net/npm/leancloud-storage@3.11.1/dist/av-min.js" async></script>
  

  
    <script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/mathjax/2.7.5/MathJax.js?config=TeX-MML-AM_CHTML" async></script>
  

  
    <script src="//unpkg.com/valine/dist/Valine.min.js" async></script>
  

  

  <script>
  // theme-ad's config script
  // it can be used in every script
  
  window.AD_CONFIG = {
    leancloud: {"appid":"eObxCkTJ6j4GzRxGLgiHyfJa-gzGzoHsz","appkey":"fzRMAFC6MCE11mp7mnvh4Kwe","comment":true,"count":true},
    welcome: {"enable":true,"interval":30},
    start_time: "2019-05-28",
    passwords: ["efe07af7441da2b69c4a41e42e73be4db47f66010a56900788a458354a7373ec", ],
    is_post: true,
    lock: false,
    author: "Amos Zhu",
    share: {"qq":true,"wechat":true},
    mathjax: true,
    page_type: "",
    root: "/blog/"
  };
</script>

  <script src="/blog/vendor/sha256.min.js"></script>
<script src="/blog/js/auth.js"></script>
<script src="/blog/js/index.js"></script>
<script src="/blog/vendor/qrcode.min.js"></script>

  
    <link rel="icon" href="/blog/images/favicon.ico">
    <link rel="apple-touch-icon" href="/blog/images/touch-icon.png">
  

  <link href="//netdna.bootstrapcdn.com/font-awesome/4.7.0/css/font-awesome.min.css" rel="stylesheet">

  <link rel="stylesheet" href="/blog/css/index.css">
<link rel="stylesheet" href="/blog/styles/components/highlight/highlight.css">

  
</head>
  <body>
    <header class="site-header">
  <div class="site-header-brand">
    
      <span class="site-header-brand-title">
        <a href="/blog/">Amos Zhu</a>
      </span>
    
    
      <span class="site-header-brand-motto"> | 当浮躁的心静不下，不妨写些东西或者看会书</span>
    
  </div>
  <div class="site-header-right">
    <nav class="site-header-navigation">
      
        <a href="/blog/" target="_self">首页</a>
      
        <a href="/blog/archives/" target="_self">归档</a>
      
        <a href="/blog/tags/" target="_self">标签</a>
      
        <a href="/blog/categories/" target="_self">分类</a>
      
        <a href="/blog/redis/" target="_self">redis</a>
      
        <a href="/blog/rabbitMQ/" target="_self">rabbitMQ</a>
      
        <a href="/blog/elasticsearch" target="_self">elasticsearch</a>
      
        <a href="/blog/stuff" target="_self">stuff</a>
      
        <a href="/blog/kafka" target="_self">kafka</a>
      
        <a href="/blog/friends/" target="_self">友链</a>
      
        <a href="/blog/about/" target="_self">关于</a>
      
    </nav>
    <div class="site-header-btn">
      
        <a href="https://gitee.com/amos_zhu" target="_blank" id="site-github">
          <i class="fa fa-github-alt"></i>
        </a>
      
      <a href="javascript:void(0);" id="site-search">
        <i class="fa fa-search"></i>
      </a>
      <a href="javascript:void(0);" id="site-nav-btn">
        <i class="fa fa-ellipsis-v"></i>
      </a>
    </div>
  </div>
</header>
<nav class="table-content" id="site-nav">
  <div class="table-content-title">
    <span>导航</span>
  </div>
  <div class="table-content-main">
    <ol class="toc">
      
        <li class="toc-item">
          <a href="/blog/" target="_self">
            首页
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/archives/" target="_self">
            归档
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/tags/" target="_self">
            标签
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/categories/" target="_self">
            分类
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/redis/" target="_self">
            redis
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/rabbitMQ/" target="_self">
            rabbitMQ
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/elasticsearch" target="_self">
            elasticsearch
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/stuff" target="_self">
            stuff
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/kafka" target="_self">
            kafka
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/friends/" target="_self">
            友链
          </a>
        </li>
      
        <li class="toc-item">
          <a href="/blog/about/" target="_self">
            关于
          </a>
        </li>
      
    </ol>
  </div>
</nav>
<div id="site-process"></div>
    <main>
      
  <div class="passage">
  <div class="passage-meta">
    <span>
      <i class="fa fa-calendar"></i>2019-07-25
    </span>
    
      <span>
        | <a href="/blog/categories/rabbitMQ/"><i class="fa fa-bookmark"></i>rabbitMQ</a>
      </span>
    
    
      <span>
        | <i class="fa fa-unlock-alt"></i>UNLOCK
      </span>
    
  </div>
  <h1 class="passage-title">
    面试那点事儿（二）
  </h1>
  
  <article class="passage-article">
    <p></p>

<h3 id="1-如何保证RabbitMQ的消息的顺序性"><a href="#1-如何保证RabbitMQ的消息的顺序性" class="headerlink" title="1. 如何保证RabbitMQ的消息的顺序性"></a>1. 如何保证RabbitMQ的消息的顺序性</h3><p>对于这个问题，我查阅很多网上的资料，大体来说主流的解决方案有两种：</p>
<ul>
<li>一种是使用单线程消费来保证消息的顺序性</li>
<li>对消息进行编号，消费者处理时根据编号来判断顺序</li>
</ul>
<p>乍一看，觉得两种方案没有什么问题，但是深入了解下，觉得这两种解决方案并不能完全接保证消息的消费的顺序性问题。</p>
<p>首先我们来分析下，是什么导致RabbitMQ消息的顺序性问题的，常见的有以下几种情形：</p>
<ul>
<li>消息生产者启用了发送确认机制，在发生超时、中断等，需要RabbitMQ补偿发送时，那么此时消息在源头就已经出现顺序混乱了，导致消息被消费时也是乱序的</li>
<li>另一种情况，如果消息发送时，设置了超时时间，并且采用了死信队列，模拟了延时队列的效果，那么此时消息的顺序也时不能保证的</li>
<li>还有一种情况，如果消息设置了优先级，那么在高并发的情况下，消息的顺序也是得不到保证的，消息的消费顺序也就不能保证了</li>
</ul>
<p>刚才我们分析了出现消息乱序的几种情况，这里我们首先排除了实用单线程来消费，原因很简单，发送的消息的顺序（源头数据的顺序出现了异常）出现了异常，单线程消费的顺序肯定也是异常的</p>
<p>其次对消息进行编号，这个可以解决消息顺序的问题，但是对加大了对业务处理的复杂性。</p>
<h3 id="2-如果RabbitMQ阻塞大量消息待消费，该怎么处理"><a href="#2-如果RabbitMQ阻塞大量消息待消费，该怎么处理" class="headerlink" title="2. 如果RabbitMQ阻塞大量消息待消费，该怎么处理"></a>2. 如果RabbitMQ阻塞大量消息待消费，该怎么处理</h3><p>一般情况下，出现这种情况，肯定是先紧急处理现场的情况， 将RabbitMQ服务中堆积的阻塞的消息消费掉， 怎么消费呢，目前能尽快处理的方案可以如下操作:</p>
<ul>
<li>一般只有比较重要的业务消息才会存储在磁盘中就行持久化（这样做主要是为了提高rabbitMQ的性能，消息全部持久化的话，对RabbitMQ的性能损耗是很高的）</li>
<li>可以通过新增多个消费者来监听业务队列来提高消息的消费速度</li>
<li>或者通过设置并发提高消息的消费速度</li>
</ul>
<p>以上只是一个应急的解决方案，我们还需要从源头来处理分析和减少消息阻塞的现象<br>消息阻塞常见的有两种情况：</p>
<ul>
<li>消息生产的速度大于消息消费的速度</li>
<li>架构设计有问题，对于消费失败的消息没有采取措施，导致消费失败的消息不断被RabbitMQ重新发送给消费者，导致消息阻塞</li>
</ul>
<p>针对上面两种情况，我们分别进行处理</p>
<ul>
<li>消息生产的速度大于消息消费的速度，我们可以设置channel.basicQos(n)来限制RabbitMQ队列中最大的未确认的消息数量，超过这个数量，rabbitMQ就不在接收生产者生产的消息，这个也是RabbitMQ的优点：削峰填谷</li>
<li>针对第二个，只能修改架构设计了，我们一方面可以通过给队列设置死信队列，同时消费端进行业务控制，如果同一个消息被消费端同时消费一次数量以上（这个数量可以通过配置参数来自由控制）将该消息手动拒绝，这样消息就会进入死信队列，然后由死信队列进行消息的持久化，或者其他的处理</li>
</ul>
<h3 id="3-如何保证RabbitMQ的负载均衡和高可用"><a href="#3-如何保证RabbitMQ的负载均衡和高可用" class="headerlink" title="3. 如何保证RabbitMQ的负载均衡和高可用"></a>3. 如何保证RabbitMQ的负载均衡和高可用</h3><p>保证RabbitMQ的负载均衡和高可用，我们可以使用RabbitMQ的普通集群、镜像集群来实现</p>
<ul>
<li>普通集群</li>
</ul>
<p>多个RabbitMQ服务安装在多个服务器上，通过RabbitMQ提供的命令来构建RabbitMQ的集群，RabbitMQ的集群比较简单，是依赖erlang集群，而erlang集群是通过这个cookie进行通信认证的，因此我们做集群的第一步就是干cookie，这个也是最重要的，其次使用RabbitMQ内部的命令来实现元数据之间的交互</p>
<p>那么RabbitMQ是怎么来实现消费者在任意一个节点上消费，即使队列节点不在这个RabbitMQ服务上也能消费呢？ </p>
<p>RabbitMQ构建集群之后，就会在各个节点之间共享元数据，元数据里面保存在该队列在哪个RabbitMQ服务的节点上，只要有消费者请求消费该节点上的消息时，该节点就是向真正有该队列的实际数据的RabbitMQ服务节点拉取消息来推送给消费者，这样就实现了消费者监听任一节点上的队列，都是能消费该队列上的消息</p>
<p>普通集群主要是加大了RabbitMQ提供服务的吞吐量，能在任意一个节点出现故障，不能对外提供服务时，只需要让消费者监听其他正常的节点即可（利用HAProxy可以解决）</p>
<p>普通集群的模式的优点不多，但是缺点不少：</p>
<ol>
<li>可能会造成RabbitMQ服务内部产生大量的数据传输</li>
<li>可用性几乎没有，如果节点中的任意节点出现了故障，不能对外服务了，其上的队列交换机等全部不可用</li>
</ol>
<ul>
<li>镜像集群模式</li>
</ul>
<p>可以这么说，该模式才是RabbitMQ真正的高可用模式,镜像，顾名思义就是每个节点上都有Queue的所有的数据，这样就能完美解决普通集群模式中的第二个缺点了，每个节点都能queue的完整的数据，任意一个节点出现了故障，其他的节点上还包含该queue的全部的数据，消费者也是可以消费到数据的</p>
<p>镜像模式依据的是策略，镜像模式在是普通模式的基础上进行的，可以在界面控制台上或者命令来实现镜像模式的搭建，比如说创建queue时，指定该queue创建或者收到消息时需要同步一个或者多个集群节点上</p>
<h3 id="4-什么是元数据？元数据分为哪些类型？包括哪些内容？与cluster相关的元数据有哪些？元数据是如何保存的？元数据在cluster中是如何分布的"><a href="#4-什么是元数据？元数据分为哪些类型？包括哪些内容？与cluster相关的元数据有哪些？元数据是如何保存的？元数据在cluster中是如何分布的" class="headerlink" title="4. 什么是元数据？元数据分为哪些类型？包括哪些内容？与cluster相关的元数据有哪些？元数据是如何保存的？元数据在cluster中是如何分布的"></a>4. 什么是元数据？元数据分为哪些类型？包括哪些内容？与cluster相关的元数据有哪些？元数据是如何保存的？元数据在cluster中是如何分布的</h3><p>在非 cluster 模式下，元数据主要分为 Queue 元数据（queue 名字和属性等）、Exchange 元数据（exchange 名字、类型和属性等）、Binding 元数据（存放路由关系的查找表）、Vhost 元数据（vhost 范围内针对前三者的名字空间约束和安全属性设置）。在 cluster 模式下，还包括 cluster 中 node 位置信息和 node 关系信息。元数据按照 erlang node 的类型确定是仅保存于 RAM 中，还是同时保存在 RAM 和 disk 上。元数据在 cluster 中是全 node 分布的。</p>
<h3 id="5-blackholed问题？如何避免blackholed问题？"><a href="#5-blackholed问题？如何避免blackholed问题？" class="headerlink" title="5. blackholed问题？如何避免blackholed问题？"></a>5. blackholed问题？如何避免blackholed问题？</h3><p>什么是blackholed问题呢？可以思考下以下的问题：</p>
<ul>
<li>如果exchange没有绑定queue，此时向exchange发送消息。</li>
<li>exchange通过bindingKeyA与queueA绑定，但是发送消息时，指定了bindingKeyB来发送消息。</li>
</ul>
<p>以上两种情况就会出现blackholed问题，造成的结果就是消息的丢失</p>
<p>那么该如何解决这个问题呢？<br>这个问题的解决方案其实在<a href="http://amos_zhu.gitee.io/blog/passages/RabbitMQ面试那点事儿/">《RabbitMQ面试那点事儿》</a>已经提到过，我们启用发送者确认机制，也可以开启mandatory来实现消息的备份等问题。</p>
  </article>
  <aside class="table-content" id="site-toc">
  <div class="table-content-title">
    <i class="fa fa-arrow-right fa-lg" id="site-toc-hide-btn"></i>
    <span>目录</span>
  </div>
  <div class="table-content-main">
    <ol class="toc"><li class="toc-item toc-level-3"><a class="toc-link" href="#1-如何保证RabbitMQ的消息的顺序性"><span class="toc-text">1. 如何保证RabbitMQ的消息的顺序性</span></a></li><li class="toc-item toc-level-3"><a class="toc-link" href="#2-如果RabbitMQ阻塞大量消息待消费，该怎么处理"><span class="toc-text">2. 如果RabbitMQ阻塞大量消息待消费，该怎么处理</span></a></li><li class="toc-item toc-level-3"><a class="toc-link" href="#3-如何保证RabbitMQ的负载均衡和高可用"><span class="toc-text">3. 如何保证RabbitMQ的负载均衡和高可用</span></a></li><li class="toc-item toc-level-3"><a class="toc-link" href="#4-什么是元数据？元数据分为哪些类型？包括哪些内容？与cluster相关的元数据有哪些？元数据是如何保存的？元数据在cluster中是如何分布的"><span class="toc-text">4. 什么是元数据？元数据分为哪些类型？包括哪些内容？与cluster相关的元数据有哪些？元数据是如何保存的？元数据在cluster中是如何分布的</span></a></li><li class="toc-item toc-level-3"><a class="toc-link" href="#5-blackholed问题？如何避免blackholed问题？"><span class="toc-text">5. blackholed问题？如何避免blackholed问题？</span></a></li></ol>
  </div>
</aside>
  
    <aside class="passage-copyright">
      <div>本文作者: Amos Zhu</div>
      
        <div>
          原文链接: 
          <a href target="_blank">http://amos_zhu.gitee.io/passages/面试那点事儿（二）/</a>
        </div>
      
      <div>
        版权声明: 本博客所有文章除特别声明外, 均采用 <a href="https://creativecommons.org/licenses/by-nc-sa/4.0/">CC BY-NC-SA 4.0</a> 许可协议. 转载请注明出处!
      </div>
    </aside>
  
  
    <div class="passage-tags">
     
      <a href="/blog/tags/rabbitMQ/"><i class="fa fa-tags"></i>rabbitMQ</a>
    
    </div>
  
</div>

    </main>
    
      
<div class="site-comment-contanier" data-plateform="leancloud">
  
    <p id="site-comment-info">
      <i class="fa fa-spinner fa-spin"></i> 评论加载中
    </p>
    <div id="site-comment"></div>
  
</div>
    
    <div class="site-footer-wrapper">
  <footer class="site-footer">
    
      
        <div class="site-footer-col">
          <h5 class="site-footer-title">博客推荐</h5>
          
            <span class="site-footer-item">
              <a href="http://youzhixueyuan.com/series/java" target="_blank">优知学院</a>
            </span>
          
            <span class="site-footer-item">
              <a href="http://ruanyifeng.com/" target="_blank">阮一峰的个人网站</a>
            </span>
          
        </div>
      
        <div class="site-footer-col">
          <h5 class="site-footer-title">系列教程</h5>
          
            <span class="site-footer-item">
              <a href="http://amos_zhu.gitee.io/blog/redis" target="_blank">Redis系列教程</a>
            </span>
          
            <span class="site-footer-item">
              <a href="http://amos_zhu.gitee.io/blog/rabbitMQ/" target="_blank">RabbitMQ教程</a>
            </span>
          
            <span class="site-footer-item">
              <a href="http://amos_zhu.gitee.io/blog/kafka/" target="_blank">Kafka架构探险</a>
            </span>
          
        </div>
      
        <div class="site-footer-col">
          <h5 class="site-footer-title">抓到我</h5>
          
            <span class="site-footer-item">
              <a href="https://gitee.com/amos_zhu" target="_blank">Gitee</a>
            </span>
          
            <span class="site-footer-item">
              <a href="https://blog.csdn.net/wdcl2468" target="_blank">CSDN</a>
            </span>
          
            <span class="site-footer-item">
              <a href="https://www.jianshu.com/u/2dbe61b1f3c3" target="_blank">简书</a>
            </span>
          
        </div>
      
    
    <div class="site-footer-info">
      <i class="fa fa-clock-o"></i> 本站已稳定运行<span id="site-time"></span>
    </div>
    
      <div class="site-footer-info">
        <i class="fa fa-paw"></i> 您是本站第 <span id="site-count"></span> 位访客
      </div>
    
    
      <div class="site-footer-info">
        <i class="fa fa-at"></i> Email: amoszhu@aliyun.com
      </div>
    
    <div class="site-footer-info">
      <i class="fa fa-copyright"></i> 
      2019 <a href="https://github.com/dongyuanxin/theme-ad/" target="_blank">Theme-AD</a>.
      Created by <a href="https://godbmw.com/" target="_blank">GodBMW</a>.
      All rights reserved.
    </div>
  </footer>
</div>
    <div id="site-layer" style="display:none;">
  <div class="site-layer-content">
    <div class="site-layer-header">
      <span class="site-layer-header-title" id="site-layer-title"></span>
      <i class="fa fa-close" id="site-layer-close"></i>
    </div>
    <div class="site-layer-body" id="site-layer-container">
      <div class="site-layer-input" id="site-layer-search" style="display: none;">
        <div class="site-layer-input-choose">
          <a href="javascript:void(0);" title="Change Search Engine">Google</a>
        </div>
        <input type="text">
        <i class="fa fa-search"></i>
      </div>
      
        <div class="site-layer-reward" id="site-layer-reward" style="display: none;">
          
            <div>
              <img src="/blog/images/wechat.png" alt="WeChat">
              
                <p>WeChat</p>
              
            </div>
          
            <div>
              <img src="/blog/images/alipay.png" alt="AliPay">
              
                <p>AliPay</p>
              
            </div>
          
        </div>
      
      <div id="site-layer-welcome" style="display:none;"></div>
    </div>
  </div>
</div>
    

<div class="bottom-bar">
  <div class="bottom-bar-left">
    <a href="/blog/passages/创建同一类型不同的对象——Builder来秀一波/" data-enable="true">
      <i class="fa fa-arrow-left"></i>
    </a>
    <a href="/blog/passages/Centos7下安装和配置SonarQube7-7/" data-enable="true">
      <i class="fa fa-arrow-right"></i>
    </a>
  </div>
  <div class="bottom-bar-right">
    <a href="javascript:void(0);" data-enable="true" id="site-toc-show-btn">
      <i class="fa fa-bars"></i>
    </a>
    
      <a href="#site-comment" data-enable="true">
        <i class="fa fa-commenting"></i>
      </a>
    
    <a href="javascript:void(0);" id="site-toggle-share-btn">
      <i class="fa fa-share-alt"></i>
    </a>
    
      <a href="javascript:void(0);" id="site-reward">
        <i class="fa fa-thumbs-up"></i>
      </a>
    
    <a href="javascript:void(0);" id="back-top-btn">
      <i class="fa fa-chevron-up"></i>
    </a>
  </div>
</div>
    <div id="share-btn">
  
  
  
  
    <a id="share-btn-qq" href="javascript:void(0);" target="_blank">
      <i class="fa fa-qq"></i>
    </a>
  
  
    <a id="share-btn-wechat" href="javascript:void(0);" target="_blank">
      <i class="fa fa-wechat"></i>
    </a>
  
</div>
    


  <script async>
  (function(){
      var bp = document.createElement('script');
      var curProtocol = window.location.protocol.split(':')[0];
      if (curProtocol === 'https') {
          bp.src = 'https://zz.bdstatic.com/linksubmit/push.js';
      }
      else {
          bp.src = 'http://push.zhanzhang.baidu.com/push.js';
      }
      var s = document.getElementsByTagName("script")[0];
      s.parentNode.insertBefore(bp, s);
  })();
  </script>



  <script async>
    (function(){
    var src = (document.location.protocol == "http:") ? "http://js.passport.qihucdn.com/11.0.1.js?":"https://jspassport.ssl.qhimg.com/11.0.1.js?";
    document.write('<script src="' + src + '" id="sozz"><\/script>');
    })();
  </script>


    
  </body>
</html>